/**   
* @Title:：RabbitClusterMsgDeliver.java 
* @Package ：com.example.deal.rabbit 
* @Description： TODO
* @author： Dustyone
* @date： 2019年4月4日 上午11:08:20  
*/
package com.example.deal.rabbit;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;

/** 
* @ClassName:：RabbitClusterMsgDeliver 
* @author ：Dustyone
* @date ：2019年4月4日 上午11:08:20  
*/

@EnableBinding(RabbitClusterChannelInterface.class)
public class RabbitClusterMsgReciever {
	
	/**
	 * 
	* @author： Dustyone
	* @Title：asiaCdsBrokerCommonNotifyMsgRecieve 
	* @Description：TODO
	* @param ：@param message 
	* @return ：void 
	* @throws
	 */
	@StreamListener(RabbitClusterChannelInterface.MESSAGE_CONFIRM_CHANNEL)
	public void mesageConfirmChannel(Message<String> message) {
		System.out.println(RabbitClusterChannelInterface.MESSAGE_CONFIRM_CHANNEL + " 确认消息接收成功：" + message.getPayload());
	}
}
